-
Notifications
You must be signed in to change notification settings - Fork 4.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fix Job Tracking Issue #1071
Fix Job Tracking Issue #1071
Conversation
return switch (output.getStatus()) { | ||
case SUCCEEDED -> JobStatus.COMPLETED; | ||
case FAILED -> JobStatus.FAILED; | ||
default -> throw new IllegalStateException("Unknown state " + output.getStatus()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This should probably log instead of throw an exception
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
mb -- I misread. This is correct.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I thoguth this was only used in tracking code not in business logic. Wouldn't have wanted to fail over tracking issues.
.env.dev
Outdated
@@ -13,7 +13,7 @@ WORKSPACE_ROOT=/tmp/workspace | |||
WORKSPACE_DOCKER_MOUNT=/tmp/dev_root/workspace | |||
LOCAL_ROOT=/tmp/airbyte_local | |||
LOCAL_DOCKER_MOUNT=/tmp/airbyte_local | |||
TRACKING_STRATEGY=logging | |||
TRACKING_STRATEGY=segment |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
todo - revert before merge. going to do this separately.
a7af49f
to
8b57fef
Compare
@@ -142,24 +142,21 @@ public void writeStandardDestinationDefinition(final StandardDestinationDefiniti | |||
destinationDefinition); | |||
} | |||
|
|||
public SourceConnection getSourceConnection(final UUID sourceId) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
blank space changes.
@@ -159,12 +159,6 @@ public SourceDefinitionSpecificationRead getSourceDefinitionSpecification(Source | |||
final String imageName = DockerUtils.getTaggedImageName(source.getDockerRepository(), source.getDockerImageTag()); | |||
final ConnectorSpecification spec = getConnectorSpecification(imageName); | |||
|
|||
TrackingClientSingleton.get().track("get_source_spec", ImmutableMap.<String, Object>builder() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is just throwing money in a bucket and lighting it on fire.
Issue: #1064
What