chore: fix lint and formatting

Author: hebaalazzeh

packages/bigframes/bigframes/core/compile/ibis_compiler/scalar_op_registry.py

@@ -1017,7 +1017,8 @@ def remote_function_op_impl(*values: ibis_types.Value, op: ops.RemoteFunctionOp)
         signature=ibis_py_sig,
         param_name_overrides=arg_names,
     )
-    def udf(*inputs): ...
+    def udf(*inputs):
+        ...
 
     return udf(*values)
 

packages/bigframes/bigframes/core/compile/polars/compiler.py

@@ -597,6 +597,7 @@ def handler(py_struct):
                     args = list(py_struct.values())
                     series_arg = function_template.get_pd_series(args[0])
                     return code(series_arg, *args[1:])
+
             else:
 
                 def handler(py_struct):

packages/bigframes/bigframes/core/compile/sqlglot/expressions/generic_ops.py

@@ -83,7 +83,9 @@ def _(*operands: TypedExpr, op: ops.GoogleSqlScalarOp) -> sge.Expression:
         if i < len(op.args):
             arg_spec = op.args[i]
         else:
-            assert op.args[-1].is_vararg, (
+            assert op.args[
+                -1
+            ].is_vararg, (
                 f"Too many arguments, for {op.sql_name}, expected {len(op.args)}"
             )
             arg_spec = op.args[-1]

packages/gapic-generator/noxfile.py

@@ -725,7 +725,7 @@ def lint(session):
     """
 
     # TODO(https://github.com/googleapis/google-cloud-python/issues/16186):
-    # SKIP: This session was not enforced in the standalone (split) repo 
+    # SKIP: This session was not enforced in the standalone (split) repo
     # and is disabled here to ensure a "move-only" migration.
     session.skip(
         "Linting was not enforced in the split repo. "
@@ -755,9 +755,11 @@ def lint(session):
 @nox.session(python=NEWEST_PYTHON)
 def lint_setup_py(session):
     # TODO(https://github.com/googleapis/google-cloud-python/issues/16186):
-    # SKIP: This session was not enforced in the standalone (split) repo 
+    # SKIP: This session was not enforced in the standalone (split) repo
     # and is disabled here to ensure a "move-only" migration.
-    session.skip("Skipping now to avoid changing code during migration. See Issue #16186")
+    session.skip(
+        "Skipping now to avoid changing code during migration. See Issue #16186"
+    )
 
 
 @nox.session(python="3.10")
@@ -832,9 +834,11 @@ def prerelease_deps(session, protobuf_implementation):
     """
     Run all tests with pre-release versions of dependencies installed.
     """
-    # TODO(https://github.com/googleapis/google-cloud-python/issues/16184): 
+    # TODO(https://github.com/googleapis/google-cloud-python/issues/16184):
     # Implement pre-release dependency logic to test against upcoming runtime changes.
-    session.skip("prerelease_deps session is not yet implemented for gapic-generator-python.")
+    session.skip(
+        "prerelease_deps session is not yet implemented for gapic-generator-python."
+    )
 
 
 @nox.session(python=NEWEST_PYTHON)
@@ -844,6 +848,8 @@ def prerelease_deps(session, protobuf_implementation):
 )
 def core_deps_from_source(session, protobuf_implementation):
     """Run all tests with core dependencies installed from source."""
-    # TODO(https://github.com/googleapis/google-cloud-python/issues/16185): 
+    # TODO(https://github.com/googleapis/google-cloud-python/issues/16185):
     # Implement logic to install core packages directly from the mono-repo directories.
-    session.skip("core_deps_from_source session is not yet implemented for gapic-generator-python.")
+    session.skip(
+        "core_deps_from_source session is not yet implemented for gapic-generator-python."
+    )

packages/gapic-generator/tests/integration/goldens/asset/google/cloud/asset_v1/__init__.py

@@ -108,10 +108,12 @@
 from .types.assets import TimeWindow
 from .types.assets import VersionedResource
 
-if hasattr(api_core, "check_python_version") and hasattr(api_core, "check_dependency_versions"):   # pragma: NO COVER
-    api_core.check_python_version("google.cloud.asset_v1") # type: ignore
-    api_core.check_dependency_versions("google.cloud.asset_v1") # type: ignore
-else:   # pragma: NO COVER
+if hasattr(api_core, "check_python_version") and hasattr(
+    api_core, "check_dependency_versions"
+):  # pragma: NO COVER
+    api_core.check_python_version("google.cloud.asset_v1")  # type: ignore
+    api_core.check_dependency_versions("google.cloud.asset_v1")  # type: ignore
+else:  # pragma: NO COVER
     # An older version of api_core is installed which does not define the
     # functions above. We do equivalent checks manually.
     try:
@@ -120,12 +122,14 @@
         _py_version_str = sys.version.split()[0]
         _package_label = "google.cloud.asset_v1"
         if sys.version_info < (3, 10):
-            warnings.warn("You are using a non-supported Python version " +
-                          f"({_py_version_str}).  Google will not post any further " +
-                          f"updates to {_package_label} supporting this Python version. " +
-                          "Please upgrade to the latest Python version, or at " +
-                          f"least to Python 3.10, and then update {_package_label}.",
-                          FutureWarning)
+            warnings.warn(
+                "You are using a non-supported Python version "
+                + f"({_py_version_str}).  Google will not post any further "
+                + f"updates to {_package_label} supporting this Python version. "
+                + "Please upgrade to the latest Python version, or at "
+                + f"least to Python 3.10, and then update {_package_label}.",
+                FutureWarning,
+            )
 
         def parse_version_to_tuple(version_string: str):
             """Safely converts a semantic version string to a comparable tuple of integers.
@@ -163,108 +167,112 @@ def _get_version(dependency_name):
         _recommendation = " (we recommend 7.x)"
         (_version_used, _version_used_string) = _get_version(_dependency_package)
         if _version_used and _version_used < _next_supported_version_tuple:
-            warnings.warn(f"Package {_package_label} depends on " +
-                          f"{_dependency_package}, currently installed at version " +
-                          f"{_version_used_string}. Future updates to " +
-                          f"{_package_label} will require {_dependency_package} at " +
-                          f"version {_next_supported_version} or higher{_recommendation}." +
-                          " Please ensure " +
-                          "that either (a) your Python environment doesn't pin the " +
-                          f"version of {_dependency_package}, so that updates to " +
-                          f"{_package_label} can require the higher version, or " +
-                          "(b) you manually update your Python environment to use at " +
-                          f"least version {_next_supported_version} of " +
-                          f"{_dependency_package}.",
-                          FutureWarning)
+            warnings.warn(
+                f"Package {_package_label} depends on "
+                + f"{_dependency_package}, currently installed at version "
+                + f"{_version_used_string}. Future updates to "
+                + f"{_package_label} will require {_dependency_package} at "
+                + f"version {_next_supported_version} or higher{_recommendation}."
+                + " Please ensure "
+                + "that either (a) your Python environment doesn't pin the "
+                + f"version of {_dependency_package}, so that updates to "
+                + f"{_package_label} can require the higher version, or "
+                + "(b) you manually update your Python environment to use at "
+                + f"least version {_next_supported_version} of "
+                + f"{_dependency_package}.",
+                FutureWarning,
+            )
     except Exception:
-            warnings.warn("Could not determine the version of Python " +
-                          "currently being used. To continue receiving " +
-                          "updates for {_package_label}, ensure you are " +
-                          "using a supported version of Python; see " +
-                          "https://devguide.python.org/versions/")
+        warnings.warn(
+            "Could not determine the version of Python "
+            + "currently being used. To continue receiving "
+            + "updates for {_package_label}, ensure you are "
+            + "using a supported version of Python; see "
+            + "https://devguide.python.org/versions/"
+        )
 
 __all__ = (
-    'AssetServiceAsyncClient',
-'AnalyzeIamPolicyLongrunningMetadata',
-'AnalyzeIamPolicyLongrunningRequest',
-'AnalyzeIamPolicyLongrunningResponse',
-'AnalyzeIamPolicyRequest',
-'AnalyzeIamPolicyResponse',
-'AnalyzeMoveRequest',
-'AnalyzeMoveResponse',
-'AnalyzeOrgPoliciesRequest',
-'AnalyzeOrgPoliciesResponse',
-'AnalyzeOrgPolicyGovernedAssetsRequest',
-'AnalyzeOrgPolicyGovernedAssetsResponse',
-'AnalyzeOrgPolicyGovernedContainersRequest',
-'AnalyzeOrgPolicyGovernedContainersResponse',
-'AnalyzerOrgPolicy',
-'AnalyzerOrgPolicyConstraint',
-'Asset',
-'AssetEnrichment',
-'AssetServiceClient',
-'AttachedResource',
-'BatchGetAssetsHistoryRequest',
-'BatchGetAssetsHistoryResponse',
-'BatchGetEffectiveIamPoliciesRequest',
-'BatchGetEffectiveIamPoliciesResponse',
-'BigQueryDestination',
-'ConditionEvaluation',
-'ContentType',
-'CreateFeedRequest',
-'CreateSavedQueryRequest',
-'DeleteFeedRequest',
-'DeleteSavedQueryRequest',
-'EffectiveTagDetails',
-'ExportAssetsRequest',
-'ExportAssetsResponse',
-'Feed',
-'FeedOutputConfig',
-'GcsDestination',
-'GcsOutputResult',
-'GetFeedRequest',
-'GetSavedQueryRequest',
-'IamPolicyAnalysisOutputConfig',
-'IamPolicyAnalysisQuery',
-'IamPolicyAnalysisResult',
-'IamPolicyAnalysisState',
-'IamPolicySearchResult',
-'ListAssetsRequest',
-'ListAssetsResponse',
-'ListFeedsRequest',
-'ListFeedsResponse',
-'ListSavedQueriesRequest',
-'ListSavedQueriesResponse',
-'MoveAnalysis',
-'MoveAnalysisResult',
-'MoveImpact',
-'OutputConfig',
-'OutputResult',
-'PartitionSpec',
-'PubsubDestination',
-'QueryAssetsOutputConfig',
-'QueryAssetsRequest',
-'QueryAssetsResponse',
-'QueryResult',
-'RelatedAsset',
-'RelatedAssets',
-'RelatedResource',
-'RelatedResources',
-'RelationshipAttributes',
-'Resource',
-'ResourceOwners',
-'ResourceSearchResult',
-'SavedQuery',
-'SearchAllIamPoliciesRequest',
-'SearchAllIamPoliciesResponse',
-'SearchAllResourcesRequest',
-'SearchAllResourcesResponse',
-'TableFieldSchema',
-'TableSchema',
-'Tag',
-'TemporalAsset',
-'TimeWindow',
-'UpdateFeedRequest',
-'UpdateSavedQueryRequest',
-'VersionedResource',
+    "AssetServiceAsyncClient",
+    "AnalyzeIamPolicyLongrunningMetadata",
+    "AnalyzeIamPolicyLongrunningRequest",
+    "AnalyzeIamPolicyLongrunningResponse",
+    "AnalyzeIamPolicyRequest",
+    "AnalyzeIamPolicyResponse",
+    "AnalyzeMoveRequest",
+    "AnalyzeMoveResponse",
+    "AnalyzeOrgPoliciesRequest",
+    "AnalyzeOrgPoliciesResponse",
+    "AnalyzeOrgPolicyGovernedAssetsRequest",
+    "AnalyzeOrgPolicyGovernedAssetsResponse",
+    "AnalyzeOrgPolicyGovernedContainersRequest",
+    "AnalyzeOrgPolicyGovernedContainersResponse",
+    "AnalyzerOrgPolicy",
+    "AnalyzerOrgPolicyConstraint",
+    "Asset",
+    "AssetEnrichment",
+    "AssetServiceClient",
+    "AttachedResource",
+    "BatchGetAssetsHistoryRequest",
+    "BatchGetAssetsHistoryResponse",
+    "BatchGetEffectiveIamPoliciesRequest",
+    "BatchGetEffectiveIamPoliciesResponse",
+    "BigQueryDestination",
+    "ConditionEvaluation",
+    "ContentType",
+    "CreateFeedRequest",
+    "CreateSavedQueryRequest",
+    "DeleteFeedRequest",
+    "DeleteSavedQueryRequest",
+    "EffectiveTagDetails",
+    "ExportAssetsRequest",
+    "ExportAssetsResponse",
+    "Feed",
+    "FeedOutputConfig",
+    "GcsDestination",
+    "GcsOutputResult",
+    "GetFeedRequest",
+    "GetSavedQueryRequest",
+    "IamPolicyAnalysisOutputConfig",
+    "IamPolicyAnalysisQuery",
+    "IamPolicyAnalysisResult",
+    "IamPolicyAnalysisState",
+    "IamPolicySearchResult",
+    "ListAssetsRequest",
+    "ListAssetsResponse",
+    "ListFeedsRequest",
+    "ListFeedsResponse",
+    "ListSavedQueriesRequest",
+    "ListSavedQueriesResponse",
+    "MoveAnalysis",
+    "MoveAnalysisResult",
+    "MoveImpact",
+    "OutputConfig",
+    "OutputResult",
+    "PartitionSpec",
+    "PubsubDestination",
+    "QueryAssetsOutputConfig",
+    "QueryAssetsRequest",
+    "QueryAssetsResponse",
+    "QueryResult",
+    "RelatedAsset",
+    "RelatedAssets",
+    "RelatedResource",
+    "RelatedResources",
+    "RelationshipAttributes",
+    "Resource",
+    "ResourceOwners",
+    "ResourceSearchResult",
+    "SavedQuery",
+    "SearchAllIamPoliciesRequest",
+    "SearchAllIamPoliciesResponse",
+    "SearchAllResourcesRequest",
+    "SearchAllResourcesResponse",
+    "TableFieldSchema",
+    "TableSchema",
+    "Tag",
+    "TemporalAsset",
+    "TimeWindow",
+    "UpdateFeedRequest",
+    "UpdateSavedQueryRequest",
+    "VersionedResource",
 )